<?php


namespace app\common\library\task;

use app\common\controller\Frontend;
use app\common\model\Order;
use think\Exception;
use think\Lang;
use think\Log;
use think\Response;
use think\queue\Job;

class OrderTask
{

    /** todo 暂无使用
     * fire方法是消息队列默认调用的方法
     * @param Job $job 当前的任务对象
     * @param array|mixed $data 发布任务时自定义的数据
     */
    public function fire(Job $job, $data)
    {
        // 执行任务
        try {
            // 执行逻辑处理(即：你需要该消息队列做什么)
//            $order = new Order();
//            $order->where('status', '=', 'active')
//                ->where('meter_is', '=', '1')
//                ->chunk(50, function ($list) use ($order, $job) {
//                    foreach ($list as $v) {
//                        if ($v->end_time < time()) {
//                            # 关闭会话更改订单状态
//                            $order->orderEndChatSessions($v->id);
//                            $job->delete();
//                        }
//                    }
//                });
        } catch (Exception $exception) {
            Log::info("执行结果出错{$exception}");
        }
    }
}